import sqlite3

# 连接到SQLite数据库（如果数据库不存在，会自动创建）
conn = sqlite3.connect('res.db')

# 创建一个cursor对象使用其执行SQL命令
cursor = conn.cursor()

# 读取data.sql文件内容
with open('data.sql', 'r',encoding='utf-8') as f:
    sql_commands = f.read()

# 分割SQL命令
sql_commands = sql_commands.split(';')

# 执行每个SQL命令
for command in sql_commands:
    try:
        cursor.execute(command)
    except sqlite3.OperationalError:
        # 如果SQL命令为空或者有错误，则跳过
        pass

# 提交更改
conn.commit()

# 关闭连接
conn.close()
